package com.smgeek.gkrpc.transport;

import com.smgeek.gkrpc.Peer;

import java.io.IOException;
import java.io.InputStream;

/**
 * @program: rpc
 *  * @description: 1.创建连接
 *  * 2.发送数据，并且等待响应
 *  * 3.关闭连接
 * @ClassName TransportClient
 * @Author wuyuyang
 * @Date 2022/1/6 16:26
 * @Description TransportClient
 * @Version 1.0
 */
public interface TransportClient {
    void connect(Peer peer);
    InputStream write(InputStream data) ;
    void close();
}
